// 聊天室的后端部分
// 引入第三方的ws模块
const WebSocket = require("ws");

// wss是一个ws服务的实例
// 监听到8080端口
const wss = new WebSocket.Server({ port: 8080 });

// 监听连接
wss.on("connection", function connection(ws) {
  // ws表示的是连接进来的那一个用户
  // 监听那个用户发送信息给后端
  ws.on("message", function message(data, isBinary) {
    // console.log("received: %s", data);
    // ws.send(data + "");

    // 广播，一个人发进来的内容，需要转发给所有连接着的用户
    wss.clients.forEach(function each(client) {
      if (client.readyState === WebSocket.OPEN) {
        client.send(data, { binary: isBinary });
      }
    });
  });

  // send发送，后端向前端发送
  // ws.send("something");
});
